package com.jeffse.light.stream.core.connector.pulsar;

import com.jeffse.light.stream.core.data.context.SourceContext;
import org.apache.pulsar.client.api.MessageListener;

public interface PulsarListener<T> extends MessageListener {
    public PulsarListener setCtx(SourceContext<T> ctx);
}
